package com.cn.daimajiangxin.flink.sink;

public class LogStats {
    private static final long serialVersionUID = 1L;
    private String source;
    private long count;

    public LogStats() {
    }

    public LogStats(String source, long count) {
        this.source = source;
        this.count = count;
    }

    public String getSource() {
        return source;
    }

    public void setSource(String source) {
        this.source = source;
    }

    public long getCount() {
        return count;
    }

    public void setCount(long count) {
        this.count = count;
    }

    @Override
    public String toString() {
        return String.format("LogStats{source='%s', count=%d}", source, count);
    }
}